package com.heima.article.job;

import com.heima.article.service.HotArticleComputeService;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;

/**
 * 热点文章定时计算
 */
@Component
public class HotArticleComputeJobHandler {

    @Autowired
    HotArticleComputeService hotArticleComputeService;

    @XxlJob("hot-article-compute-jobhandler")//值要和调度中心  热点文章定时计算执行器下  任务的  JobHandler值保持一致
    //目前用的轮训策略   因为前5天文章数据量不是太多   单节点可以计算完
    //如果前5天已发布文章数据量太大，需要考虑用分片广播
    public void hotArticleCompute(){
        System.out.println("热点文章计算任务执行了"+new Date());

        hotArticleComputeService.hotArticleCompute();
    }
}
